package com.xcc.core.netty.coder;



import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.MessageToByteEncoder;

public class ShenSuEncoder extends MessageToByteEncoder<byte[]>{
    
    @Override
    protected void encode(ChannelHandlerContext ctx, byte[] msg, ByteBuf out)
        throws Exception {
        System.out.println(msg);
        int[] end =new int[] { 0xef, 0xbc,  0xa0,  0xe6 ,  0xe8,  0x8b ,  0x8f,   0x83};
        byte[] endBytes=new byte[8];
        for(int i=0;i<end.length;i++) {
            endBytes[i]=(byte)end[i];
        }
    //    ByteBuffer buf2 = ByteBuffer.allocate(msg.length);
     //   buf2.put(endBytes);
    //    System.out.println(buf2);
        // 写入消息主体
        out.writeBytes(endBytes);
//        out.writeBytes(endBytes);
     //   out.add(msg);
    //    out.readBytes(buf2 ,0,msg.length);
    //    for(byte c:msg) { System.out.print(Integer.toHexString((c&0xFF))+" "); }
        
    }

    public   int toInt(byte[] bytes){
        int number = 0;
        for(int i = 0; i < 4 ; i++){
            number += bytes[i] << i*8;
        }
        return number;
    }
  

}
